package com.lw.service.impl;

import com.lw.common.utils.CallApiWrapperUtils;
import com.lw.service.RealTimeDataService;
import com.mybatisflex.core.util.StringUtil;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Component;

import java.util.HashMap;

/**
 * 实时数据 接口
 * by lw on 2025年2月20日11:04:36
 * 注意： 关键字 “Tb” 是代表数据库表： table的意思。
 * 例如： TbUser 表示数据库中存在该表的javabean，以此类推 Service，Controller等
 * 非Tb开头的javabean或service，则没有对应表。 例如：RealTimeDataServiceImpl 是数据库没有该表的 业务service
 */
@Component
public class RealTimeDataServiceImpl implements RealTimeDataService {


    @Resource
    CallApiWrapperUtils callApiWrapper;

    @Override
    public String getSurfChnPreMin() {
        HashMap<String, String> params = new HashMap<>();
        params.put("dataCode", "SURF_CHN_PRE_MIN");
        params.put("elements", "Station_Id_C,Station_levl,Lat,Lon,Alti,Admin_Code_CHN,V_ACODE_4SEARCH,Town_code,City,Station_Name,Cnty,COUNTRYCODE,Country,NetCode,Province,REGIONCODE,Town,UPDATE_TIME,Hour,Mon,Station_Type,Min,Day,REP_CORR_ID,V08010,PRE_Sensor_Heigh,Year,V02175,Q13011,PRE,IYMDHM,Datetime");
        params.put("staIds", "54511");
        params.put("times", "20250219000000");
        params.put("limitCnt", "10");
        String surfChnPreMin = callApiWrapper.callApiWrapperStr("getSurfEleByTimeAndStaID", params);
        if(StringUtil.isBlank(surfChnPreMin)) {
            System.out.println("调用报错,无法入库");
            return "";
        }
        //写入数据库中

        System.out.println("========" + surfChnPreMin);
       return "ok";
    }

    @Override
    public String getSurfChnMulMin() {
        return "";
    }

    @Override
    public String getSurfChnMulHor() {
        return "";
    }
}
